fae6f16fa0c5679d5aae1029268f122de4ebd816,vertx-cassandra/src/main/java/com/englishtown/vertx/cassandra/impl/JsonCassandraConfigurator.java,JsonCassandraConfigurator,initPoolingOptions,#JsonObject#,273

Before Change


        if (new_connection_threshold_remote != null) {
            poolingOptions.setNewConnectionThreshold(HostDistance.REMOTE, new_connection_threshold_remote);
        } else {
            Integer max_simultaneous_requests_remote = poolingConfig.getInteger("max_simultaneous_requests_remote");
            if (max_simultaneous_requests_remote != null) {
                poolingOptions.setNewConnectionThreshold(HostDistance.REMOTE, max_simultaneous_requests_remote);
            }

After Change


        Integer core_connections_per_host_local = poolingConfig.getInteger("core_connections_per_host_local");
        Integer core_connections_per_host_remote = poolingConfig.getInteger("core_connections_per_host_remote");
        Integer heartbeat_interval_seconds = poolingConfig.getInteger("heartbeat_interval_seconds");
        Integer idle_timeout_seconds = poolingConfig.getInteger("idle_timeout_seconds");
        Integer max_connections_per_host_local = poolingConfig.getInteger("max_connections_per_host_local");
        Integer max_connections_per_host_remote = poolingConfig.getInteger("max_connections_per_host_remote");
        Integer max_queue_size = poolingConfig.getInteger("max_queue_size");
        Integer max_requests_per_connection_local = poolingConfig.getInteger("max_requests_per_connection_local");
        Integer max_requests_per_connection_remote = poolingConfig.getInteger("max_requests_per_connection_remote");
        Integer new_connection_threshold_local = poolingConfig.getInteger("new_connection_threshold_local");
        Integer new_connection_threshold_remote = poolingConfig.getInteger("new_connection_threshold_remote");